package com.wzl.consumer.service.kafkaService.impl.basicsConsumer;

import com.wzl.consumer.mapper.kafkaMqMapper.basicsConsumer.MqBasicsKafkaConMapper;
import com.wzl.consumer.service.kafkaService.basicsConsumer.MqBasicsKafkaConService;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**
 * kafka消费者接口实现类
 * @author weizhongli
 * @since 2022-09-14 11:35
 */
@Service
public class MqBasicsKafkaConServiceImpl implements MqBasicsKafkaConService {

    @Resource
    private MqBasicsKafkaConMapper mqBasicsKafkaConMapper;

    @Override
    public void updateUserById(Integer id, String userName) {
        mqBasicsKafkaConMapper.updateUserById(id, userName);
    }
}